#!/bin/bash
mkdir -p /home/hadoop/start-streaming
aws s3 cp s3://streaming/flink/script/start_streaming.py /home/hadoop/start-streaming/
mkdir -p /home/hadoop/flink-jar
aws s3 cp s3://streaming/flink/jar/hm-iot-streaming.jar /home/hadoop/flink-jar/
/usr/bin/python3 -u /home/hadoop/start-streaming/start_streaming.py $1 $2 >> /home/hadoop/start-streaming/start_streaming.log